//package com.ytjj.qmyx.mall.kafka;
//
//import org.springframework.cloud.stream.annotation.Output;
//import org.springframework.messaging.MessageChannel;
//
//public interface IPvKafkaOut {
//    String PV_KAFKA_OUT="output-pv";
//
//    String PV_NEW_KAFKA_OUT="output-pv-new";
//
//    String PV_HISTORY = "pv_history";
//
//    @Output(PV_KAFKA_OUT)
//    MessageChannel output();
//
//    @Output(PV_NEW_KAFKA_OUT)
//    MessageChannel pvNewOutput();
//
//    @Output(PV_HISTORY)
//    MessageChannel historyOutput();
//}
